const db = require("../models");

class AlarmRecordRepository {
  // 获取所有报警记录
  async getAllAlarmRecords() {
    return await db.AlarmRecord.findAll();
  }

  // 根据ID获取报警记录
  async findById(id) {
    return await db.AlarmRecord.findByPk(id);
  }

  // 创建新的报警记录
  async create(alarmRecordData) {
    return await db.AlarmRecord.create(alarmRecordData);
  }

  // 更新报警记录
  async update(id, alarmRecordData) {
    const alarmRecord = await db.AlarmRecord.findByPk(id);
    if (alarmRecord) {
      return await alarmRecord.update(alarmRecordData);
    }
    return null;
  }

  // 删除报警记录
  async delAlarmRecordById(id) {
    const alarmRecord = await db.AlarmRecord.findByPk(id);
    if (alarmRecord) {
      await alarmRecord.destroy();
      return true;
    }
    return false;
  }
}

module.exports = new AlarmRecordRepository();
